{"nbformat":4,"nbformat_minor":0,"metadata":{"colab":{"provenance":[],"authorship_tag":"ABX9TyMcCz5tVu75Ga7qZsQ+F0BQ"},"kernelspec":{"name":"python3","display_name":"Python 3"},"language_info":{"name":"python"}},"cells":[{"cell_type":"code","execution_count":8,"metadata":{"colab":{"base_uri":"https://localhost:8080/","height":559},"id":"pfuFWtQpQz4n","executionInfo":{"status":"ok","timestamp":1747050826077,"user_tz":-330,"elapsed":56407,"user":{"displayName":"BMHS Shobhit University","userId":"16906612428237349049"}},"outputId":"d967dbc9-36ae-4d14-a294-aa85d95ddb18"},"outputs":[{"output_type":"display_data","data":{"text/html":["\n","\n","\n"," \n","\n",""]},"metadata":{}},{"output_type":"stream","name":"stdout","text":["Real-time visualization stopped.\n"]}],"source":["import requests\n","import time\n","from datetime import datetime\n","from collections import deque\n","import plotly.graph_objects as go\n","from IPython.display import display, clear_output\n","import gspread\n","from google.oauth2.service_account import Credentials\n","from google.colab import files # Colab-specific import for file upload\n","\n","# Step 1: Upload your Google Service Account JSON file\n","print(\"Please upload your Google Service Account JSON file.\")\n","uploaded = files.upload() # This will prompt you to upload the file\n","credentials_file = list(uploaded.keys())[0] # Use the uploaded file's name\n","\n","# Configuration\n","data_url = 'https://6fc0-2405-201-6815-261-31fc-f5ec-fd9a-d83b.ngrok-free.app/data' # Replace with your Ngrok URL\n","num_channels = 1 # Number of EEG channels\n","buffer_size = 512 # Number of points to show on the graph\n","signal_buffers = [deque([0] * buffer_size, maxlen=buffer_size) for _ in range(num_channels)]\n","\n","# Initialize Plotly figure\n","fig = go.Figure()\n","\n","# Add traces for all channels to a single graph\n","for i in range(num_channels):\n"," fig.add_trace(go.Scatter(y=[], mode='lines', name=f'Channel {i}'))\n","\n","fig.update_layout(\n"," title=\"Real-time EEG Signal Visualization\",\n"," xaxis_title=\"Time\",\n"," yaxis_title=\"Signal Value\",\n"," xaxis=dict(range=[0, buffer_size]), # Fixed x-axis range\n"," yaxis=dict(), # Adjust based on sensor value range\n"," showlegend=True,\n",")\n","\n","# Step 2: Set up Google Sheets\n","scope = [\"https://spreadsheets.google.com/feeds\", \"https://www.googleapis.com/auth/drive\"]\n","credentials = Credentials.from_service_account_file(credentials_file, scopes=scope)\n","client = gspread.authorize(credentials)\n","\n","# Open the existing Google Sheet by its key\n","sheet_key = \"175qYNdMyPRX4qW-1kQLZKT9Pz6JQwEJ7Rqi0H5z5vAs\"\n","sheet = client.open_by_key(sheet_key).sheet1\n","\n","# Write column headers to the Google Sheet\n","headers = [\"Time\"] + [f\"A{i}\" for i in range(num_channels)]\n","sheet.clear() # Clear any existing data in the sheet\n","sheet.append_row(headers) # Add headers\n","\n","# Buffer for batch writing to Google Sheets\n","batch_buffer = []\n","BATCH_SIZE = 10 # Number of data points to collect before writing to the sheet\n","\n","# Step 3: Real-time data fetching and plotting\n","try:\n"," while True:\n"," try:\n"," # Fetch data from the server\n"," response = requests.get(data_url, timeout=5)\n"," if response.status_code == 200:\n"," values = response.json()\n","\n"," # Ensure valid data format\n"," if len(values) == num_channels:\n"," # Add the current timestamp to the data\n"," timestamp = datetime.now().strftime(\"%Y-%m-%d %H:%M:%S\")\n"," row_with_time = [timestamp] + values\n","\n"," # Update buffers with new data\n"," for i in range(num_channels):\n"," signal_buffers[i].append(values[i])\n","\n"," # Update Plotly data\n"," for i in range(num_channels):\n"," fig.data[i].y = list(signal_buffers[i])\n","\n"," # Add data to batch buffer for Google Sheets\n"," batch_buffer.append(row_with_time)\n","\n"," # If batch buffer reaches the defined size, write to Google Sheets\n"," if len(batch_buffer) >= BATCH_SIZE:\n"," print(\"Writing batch data to Google Sheets...\")\n"," try:\n"," # Write the batch data to the sheet\n"," sheet.append_rows(batch_buffer) # Write all rows in the batch\n"," batch_buffer = [] # Clear the buffer after writing\n"," except gspread.exceptions.APIError as e:\n"," print(f\"Error writing to Google Sheets: {e}\")\n"," time.sleep(10) # Wait for a while before retrying\n","\n"," # Render the updated figure in Colab without flicker\n"," clear_output(wait=True)\n"," display(fig)\n","\n"," # Reduce update frequency to prevent flickering\n"," time.sleep(0.2) # Adjust this value to control the smoothness\n","\n"," else:\n"," print(\"Invalid data format received:\", values)\n"," else:\n"," print(f\"Failed to fetch data. Status code: {response.status_code}\")\n"," except requests.exceptions.RequestException as e:\n"," print(\"Error fetching data:\", e)\n"," time.sleep(1) # Retry after a delay\n","except KeyboardInterrupt:\n"," print(\"Real-time visualization stopped.\")\n"]}]}